package com.mhg.socket;

import java.net.*;
import java.io.*;
//客户端
//Tcp 面向连接 在建立Socket服务前 必须保证服务器已经开启
class Demo_01_Tcp_Client 
{
	public static void main(String[] args) throws Exception
	{
		//1.创建一个Socket 并且指定要连接的主机和端口号
		Socket socket = new Socket("127.0.0.1",10010);
		//2.向服务器端 发送数据 为了发送数据 必须使用流 必须获取Socket中的 输出流
		OutputStream out = socket.getOutputStream();
		out.write("tcp 我来啦".getBytes());
		//3.关闭
		socket.close();
	}
}
//服务器端
class Demo_01_Tcp_Server
{
	public static void main(String[] args) throws Exception{
		//1.创建一个ServerSocket对象 指定端口
		ServerSocket ss = new ServerSocket(10010);
		while(true){
			//2.获取连接来的 客户端
			Socket socket = ss.accept();
			//获取 ip地址
			String ip = socket.getInetAddress().getHostAddress();
			System.out.println(ip+"....连接啦!");
			//3.获取数据 客户端发送过来的数据 对于服务器端来说 是in
			InputStream in = socket.getInputStream();
			byte[] buf = new byte[1024];
			int len = in.read(buf);
			System.out.println(new String(buf,0,len));
		}
	}
}
